package org.example.chapter2;

import rx.Observable;
import rx.functions.Action1;

public class Demo2_1_1 {
    public static void main(String[] args) {
        Observable.range(10,5).subscribe(new Action1<Integer>() {
            @Override
            public void call(Integer integer) {
                System.err.println("Integer = " + integer);
            }
        });
    }
}
